package com.scgaopan.disruptor.pakingdemo.handler;

import com.lmax.disruptor.EventHandler;
import com.scgaopan.disruptor.pakingdemo.DateUtil;
import com.scgaopan.disruptor.pakingdemo.MyInParkingDataEvent;

/**
 * Author:scgaopan
 * Date:18/10/25
 * Description:
 */
public class MyParkingDataSmsHandler implements EventHandler<MyInParkingDataEvent> {

    public void onEvent(MyInParkingDataEvent event, long sequence, boolean endOfBatch) throws Exception {
        //Thread.sleep(1000);
        System.out.println(DateUtil.getCurrentTime()+ "发送消息成功，当前线程="+Thread.currentThread().getId()+" data="+event.getCarLicense());
    }
}
